package start.spring.basic.service;

import org.apache.kafka.clients.consumer.ConsumerRecords;

/**
 * 
 * ****************************************************************************
 * kafka消费者业务逻辑处理service
 *
 * @author(作者)：xuyongyun	
 * @date(创建日期)：2023年2月16日
 ******************************************************************************
 */
public interface IKfkConsumerHandleService {
	
	/**
	 * 批量消息业务处理入口，是否需要开多线程加快处理速度，根据实际业务确定
	 *	
	 * @param msg
	 * @return
	 * @throws Exception
	 * @since           1.0
	 */
    void handle(ConsumerRecords<String,String> records) throws Exception;

}
